google.golang.org/grpc.clientStream.callInfo (field)
14 uses
google.golang.org/grpc (current package)
stream.go#L330: callInfo: callInfo,
stream.go#L418: ctx := newContextWithRPCInfo(cs.ctx, cs.callInfo.failFast, cs.callInfo.codec, cs.compressorV0, cs.compressorV1)
stream.go#L423: ctx = sh.TagRPC(ctx, &stats.RPCTagInfo{FullMethodName: method, FailFast: cs.callInfo.failFast, NameResolutionDelay: cs.nameResolutionDelay})
stream.go#L428: FailFast: cs.callInfo.failFast,
stream.go#L473: pick, err := cs.cc.pickerWrapper.pick(a.ctx, cs.callInfo.failFast, pickInfo)
stream.go#L540: callInfo *callInfo
stream.go#L892: if cs.replayBufferSize > cs.callInfo.maxRetryRPCBufferSize {
stream.go#L936: if payloadLen > *cs.callInfo.maxSendMessageSize {
stream.go#L937: return status.Errorf(codes.ResourceExhausted, "trying to send message larger than max (%d vs. %d)", payloadLen, *cs.callInfo.maxSendMessageSize)
stream.go#L1041: for _, onFinish := range cs.callInfo.onFinish {
stream.go#L1050: o.after(cs.callInfo, cs.attempt)
stream.go#L1142: if err := recv(a.parser, cs.codec, a.transportStream, a.decompressorV0, m, *cs.callInfo.maxReceiveMessageSize, payInfo, a.decompressorV1, false); err != nil {
stream.go#L1175: if err := recv(a.parser, cs.codec, a.transportStream, a.decompressorV0, m, *cs.callInfo.maxReceiveMessageSize, nil, a.decompressorV1, false); err == io.EOF {